package com.ssmr.demo.service;

import com.ssmr.demo.entity.TPurchaseRecord;

public interface RabbitmqConsumerService {

    /*一个坑:微服务，并发消费rabbitmq消息,如何保证入库的数据是最新的?
     * https://my.oschina.net/wangkang80/blog/1552213
     * 这里只是insert,不是update,所以不需要比较version*/
    void consumePurchaseRecordMessage(TPurchaseRecord tPurchaseRecord);

    void updateProductAsync(TPurchaseRecord tPurchaseRecord);
}
